e7df25f6ef1f391aae38f43658983ee10a165a33,tests/junit/org/jgroups/tests/ConnectStressTest.java,ConnectStressTest,testConcurrentLeaves,#,100
Before Change
int num_members=0;
for(int i=0; i < 10; i++) {
num_members=channel.getView().getMembers().size();
System.out.println("*--* number of members connected: " + num_members + ", (expected: 1)");
if(num_members == 1)
break;
Util.sleep(500);
}
assertEquals(1, num_members);
}
After Change
int num_members=0;
for(int i=0; i < 10; i++) {
View v=channel.getView();
Vector mbrs=v != null? v.getMembers() : null;
if(mbrs != null) {
num_members=mbrs.size();
System.out.println("*--* number of members connected: " + num_members + ", (expected: 1)");
if(num_members == 1)
break;
}
Util.sleep(500);
}
assertEquals(1, num_members);
}